package com.example.concurrentprogramming8016.disruptor.produceconsumer.singleproduceconsumer;


import com.lmax.disruptor.EventHandler;

/**
 * @author liyanhao
 * @Date 2023-01-08 11:42
 */
public class OrderEventHandler implements EventHandler<OrderEvent> {
    @Override
    public void onEvent(OrderEvent event, long sequence, boolean endOfBatch) throws Exception {
        //消费逻辑 TODO
        System.out.println("消费者获取数据value:"
                +event.getValue()+",name:"
                +event.getName());
    }
}
